package com.qianmi.kfk.consume;

import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @Description
 * @Author 蔡超[of3379]
 * @date 2020.07.05 17:39
 */
@Slf4j
@Component
public class EhrAgreementListener {
    @KafkaListener(topics = {"yemu"})
    public void annul1(ConsumerRecord<String, String> record) {
        log.info("接收到消息" + record.toString());
    }

}
